package cn.jinzhu.stream;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
//消息接受器 2
@EnableBinding(MyMsggChannel.class)//绑定我自己的自定义消息通道
public class MsgReceiver2 {

    @StreamListener(MyMsggChannel.INPUT)//监听自定义消息通道监听器
    public void receiver(Object object){
        System.out.println(object);
    }
}
